package cn.gwm.flink.streaming.ods.model;

import cn.hutool.db.Entity;
import lombok.Data;

import java.io.Serializable;

@Data
public class StandardModelConf implements Serializable {

    String id;

    String taskName;
    String modelType;

    String vehicleType;

    String modelName;

    String topicName;

    String fieldVehicleType;
    String fieldVersion;

    String hbaseTableName;

    String hiveCanPath;

    String canPrefix;

    String gpsPrefix;

    String hiveGpsPath;

    String requestPrefix;

    String hiveRequestPath;

    String kafkaFlag;

    String hbaseFlag;

    String hiveFlag;

    String parallelism;

    String deleted;

    /**
     * 规则流表名
     */
    public static final String TABLE_NAME = "standard_model_conf";

    public static Entity getEntityWhere() {

        Entity entity = new Entity(TABLE_NAME).parseBean(new StandardModelConf(), true, true);
        return entity;
    }
}
